package com.cfpamf.athean.rabbit.mq.plus.domain.po;

import java.io.Serializable;
import java.time.LocalDateTime;

import com.baomidou.mybatisplus.annotation.TableName;

import lombok.Getter;
import lombok.Setter;

/**
 * <p>
 * rabbitMqPlus消费任务表
 * </p>
 *
 * @author Andy（陈洪桥）
 * @since 2022-12-11 22:32:32
 */
@Getter
@Setter
@TableName("rabbit_mq_plus_consumer_task")
public class RabbitMqPlusConsumerTaskPO implements Serializable {

    private static final long serialVersionUID = 1L;

    private Long id;

    private String queueName;

    private String consumerTypeCode;

    private String consumerTypeDesc;

    private Integer statusCode;

    private String statusDesc;

    private String consumerTag;

    private String consumerListenerImplClassName;
    
    private Integer maxRetryCount;

    private Integer retryCount;

    private LocalDateTime nextExecuteTime;

    private LocalDateTime firstConsumerTime;

    private LocalDateTime consumerTime;

    private String messageBody;

    private String createBy;

    private LocalDateTime createTime;

    private String updateBy;

    private LocalDateTime updateTime;

    private Integer enabledFlag;

}
